type golang.org/x/net/http2.stream
28 uses
golang.org/x/net/http2 (current package)
server.go#L413: streams: make(map[uint32]*stream),
server.go#L586: streams map[uint32]*stream
server.go#L634: type stream struct {
server.go#L667: func (sc *serverConn) state(streamID uint32) (streamState, *stream) {
server.go#L1091: func (sc *serverConn) writeDataFromHandler(stream *stream, data []byte, endStream bool) error {
server.go#L1623: func (sc *serverConn) closeStream(st *stream, err error) {
server.go#L1866: func (st *stream) isPushed() bool {
server.go#L1872: func (st *stream) endStream() {
server.go#L1888: func (st *stream) copyTrailersToHandlerRequest() {
server.go#L1899: func (st *stream) onReadTimeout() {
server.go#L1907: func (st *stream) onWriteTimeout() {
server.go#L2049: func (st *stream) processTrailerHeaders(f *MetaHeadersFrame) error {
server.go#L2098: func (sc *serverConn) newStream(id, pusherID uint32, state streamState) *stream {
server.go#L2105: st := &stream{
server.go#L2134: func (sc *serverConn) newWriterAndRequest(st *stream, f *MetaHeadersFrame) (*responseWriter, *http.Request, error) {
server.go#L2199: func (sc *serverConn) newWriterAndRequestNoBody(st *stream, rp requestParam) (*responseWriter, *http.Request, error) {
server.go#L2274: func (sc *serverConn) newResponseWriter(st *stream, req *http.Request) *responseWriter {
server.go#L2327: func (sc *serverConn) writeHeaders(st *stream, headerData *writeResHeaders) error {
server.go#L2359: func (sc *serverConn) write100ContinueHeaders(st *stream) {
server.go#L2369: st *stream
server.go#L2376: func (sc *serverConn) noteBodyReadFromHandler(st *stream, n int, err error) {
server.go#L2386: func (sc *serverConn) noteBodyRead(st *stream, n int) {
server.go#L2397: func (sc *serverConn) sendWindowUpdate32(st *stream, n int32) {
server.go#L2402: func (sc *serverConn) sendWindowUpdate(st *stream, n int) {
server.go#L2425: stream *stream
server.go#L2480: stream *stream
server.go#L3062: parent *stream
writesched.go#L57: stream *stream